# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

jms_dim__dim_yl_tmsnew_tms_vehicle_line_base_dt = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dim__dim_yl_tmsnew_tms_vehicle_line_base_dt",
    filepath='/dw/hive/jms_dim.db/external/dim_yl_tmsnew_tms_vehicle_line_base_dt/dt={{ execution_date | date_add(-1) | cst_ds }}',
    #execution_timeout=timedelta(hours=7)
    #excel平均时长:0
    execution_timeout = timedelta(minutes=30),
    #邮箱更换
    email=['jarl.huang@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)
